package com.topsun.framework;

//import org.springframework.cloud.stream.annotation.Input;
//import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface KafkaChannel {

    /**
     * 发送消息通道名称
     */
    String DEFAULT_OUTPUT = "default_output";

    /**
     * 接收消息通道名称
     */
    String DEFAULT_INPUT = "default_input";


    /**
     * 发送消息通道
     * @return channel 返回信息发送通道
     */
//    @Output(DEFAULT_OUTPUT)
    MessageChannel sendDefaultMessage();



    /**
     * 接收消息通道
     * @return channel 返回信息接收通道
     */
//    @Input(DEFAULT_INPUT)
    MessageChannel recieveDefaultMessage();
}
